package com.sh.data.engine.domain.dataquality.service;

import com.sh.data.engine.repository.dao.dataquality.entity.DataQualityJobEntity;

import java.util.List;

/**
 * @author tinglan.ys
 * @description:
 * @date 2022/2/25 下午2:11
 */
public interface DataQualityService {

    /**
     * @description : 执行数据质量任务 试跑的话要指定规则id 定时任务无需指定规则，跑这个表的所有规则
     * @author : tinglan.ys
     * @date : 2022/3/9
     */
    void processDataQuality(
        Long projectId, Long tblId, List<Long> ruleIds, Integer cycle, Long partitionId);

    /**
     * @description : 插入最新的任务
     * @author : tinglan.ys
     * @date : 2022/3/9
     */
    void insertNewestJob(DataQualityJobEntity dataQualityJob, String userId);

    Integer getLastJobStatus(Long projectId, Long tblId);
}
